06b4a9f8715eb717112323437991eab5a7971101,xwiki-platform-core/xwiki-platform-observation/xwiki-platform-observation-remote/src/main/java/org/xwiki/observation/remote/internal/jgroups/JGroupsNetworkAdapter.java,JGroupsNetworkAdapter,createChannel,#String#,163
Before Change
private JChannel createChannel(String channelId) throws Exception
{
// load configuration
ProtocolStackConfigurator channelConf = loadChannelConfiguration(channelId);
// get Receiver
JGroupsReceiver channelReceiver;
try {
channelReceiver = this.componentManager.lookup(JGroupsReceiver.class, channelId);
} catch (ComponentLookupException e) {
channelReceiver = this.componentManager.lookup(JGroupsReceiver.class);
}
// create channel
JChannel channel = new JChannel(channelConf);
channel.setReceiver(channelReceiver);
channel.setDiscardOwnMessages(true);
After Change
// load configuration
ProtocolStackConfigurator channelConf;
try {
channelConf = loadChannelConfiguration(channelId);
} catch (IOException e) {
throw new ChannelException("Failed to load configuration for the channel [" + channelId + "]", e);
}
// get Receiver
JGroupsReceiver channelReceiver;
try {
channelReceiver = this.componentManager.lookup(JGroupsReceiver.class, channelId);
} catch (ComponentLookupException e) {
channelReceiver = this.componentManager.lookup(JGroupsReceiver.class);
}
// create channel
JChannel channel = new JChannel(channelConf);
channel.setReceiver(channelReceiver);
channel.setOpt(JChannel.LOCAL, false);